package model

type KafkaConsumerModel struct {
	StartFunc     string
	GroupId       string
	Topics        []string
	CustomerCount int
	StopChan      map[int64]chan struct{}
}

// KafkaProducerModel 生产者随机分配生产模型，随机选择一个生产类型即可。
// 但是要保证主题个数和生产者数量相同，即保证一个生产模型给一个主题去生产消息
type KafkaProducerModel struct {
	Topics        []string
	ProducerCount int
	StopChan      map[int64]chan struct{}
}
